package com.summer.rx.impl;

/**
 * 观察者
 */
public abstract class Observer<T> {

    public abstract void onNext(T value);

    public abstract void onComplete();

    public abstract void onError(Throwable ex);

}
